#from dask.distributed import Client, progress
#import numpy as np
#import os
#os.environ["MODIN_ENGINE"] = "dask"  # Modin will use Ray
#import multiprocessing as mp
#
#if __name__ == '__main__':
#    client = Client(n_workers=2)
#    import modin.pandas as pd
#    mp.freeze_support()
#    frame_data = np.random.randint(0, 100, size=(2**10, 2**8))
#    df = pd.DataFrame(frame_data)
#    print("====数据描述====\n", df)


#from dask.distributed import Client, progress
from distributed import Client
#client = Client()
#import modin.pandas as pd
import numpy as np

if __name__ == "__main__":
    client = Client()
    import modin.pandas as pd
    frame_data = np.random.randint(0, 100, size=(2**10, 2**8))
    df = pd.DataFrame(frame_data)
    #client = Client(n_workers=2)
    #import modin.pandas as pd
    #path= "var/modin"
    #modin_df = np.random.randint(0, 100, size=(2**10, 2**8))
    print('======使用Dask引擎====\n', df)

